package com.stf.rocketmq.util;

public class MqUtil {


    //同步消息String
    public static final String  async_topic_string = "syncStringTopic";

    public static final String  async_topic_string_tags = "syncStringTopicTags";

    //普通消息
    public static final String  async_topic_obejct = "syncStringObejct";

    //普通同步消息-msg
    public static final String  async_topic_msg = "syncStringMsg";

    //批量普通同步消息
    public static final String  async_topic_collection = "syncStringCollection";

    //同步延迟消息
    public static final String  async_delayed_str = "syncSendDelayedStr";




    //异步消息
    public static final String  async_topic_ = "async_topic_string";





    //单向消息
    public static final String  oneway_topic = "oneway_topic_string";
}
